温度平均值计算

场景描述

当温度计测试的物体比较大时，单个温度计的测量值不能很好的表现设备的状态，需要综合多个观测点的温度才能得出物体整体的状态。本文以计算锅炉多个温度平均值的场景为例，详细说明如何使用组件编排进行流数据分析作业的编写以及流数据分析作业如何运作。

操作流程

1. 创建产品和设备

   • 参照示例说明>新建产品（MQTT）和设备章节创建产品，设备和产品功能属性。本示例创建了温度（temperature）和监测设备（targetDevice）2个属性。

     

2. 创建输出表

   • 使用数据库连接工具连接到配置的数据库，编写标准sql创建表。
   • 创建输出数据库表：test_out,包含如下4个字段：createTime,deviceId,targetDevice,value。

3. 新建任务

   • 登录边缘管理平台，通过 数据分析>数据分析管理>添加数据分析任务 创建如下任务：

     

4. 任务编辑

   • 设备输入配置：根据创建的产品，设备和属性选择相应的项，点击确定。

     

   • 聚合计算配置：勾选计算维度，计算度量和统计函数。然后输入时间窗口大小，点击确定。

   说明： 计算维度相当于sql任务的group by后面的字段，计算度量相当于sql任务的统计函数作用的字段，一般是数值类型。

   

   • 数据源输出配置：根据相应的输入字段，选择输出到对应的数据库表字段中，点击确定。

   注意字段类型和数据库表字段类型必须兼容，否则会出现异常。

   

   任务编辑完成，点击右上角的保存按钮，保存任务。如果出现错误信息，则根据返回的错误信息更改配置，直到没有错误为止，否则提交任务时也不会成功。

5. 下发任务到边缘端

   • 按照示例说明>部署数据分析任务章节下发数据分析任务到相应边缘节点执行。

6. 模拟设备上传数据和查看运行结果

   • 参照实例说明>设备上报数据章节内容，开启模拟数据脚本，模拟设备上传数据。

   • 查看指定输出数据源中数据表数据：使用任意的数据库连接工具，连到输出数据源指定的数据库，查询相应的数据库表最新的数据，会出现相应的计算结果。